# -*- coding: utf-8 -*-
# @Time    : 2022-12-02 20:13
# @Author  : CMS！！
# @FileName: 3.py
# @Software: PyCharm


# 2  设计一个留言版的表（留言ID，留言内容，留言人，留言审核状态，留言时间）
# （表名，和字段名自己设计成英文：注意，不要用中文，用中文的直接0分）；

# 使用PyMySQL 驱动模块，实现对这个表的增加，删除，修改，查询；数据库操作需要加入异常处理逻辑；

import pymysql

# 打开数据库连接
db = pymysql.connect(host='localhost', user='root', password='2267000140aa!', db='test')

# 使用cursor()方法获取操作游标
cursor = db.cursor()

# SQL 插入语句
# sql = """INSERT INTO MESSAGE(ID,
#          text, person, view, time)
#          VALUES (1, 'chizaofan', 'hery', 1, now())"""
# try:
#     # 执行sql语句
#     cursor.execute(sql)
#     # 提交到数据库执行
#     db.commit()
#     print("提交成功")
# except:
#     # 如果发生错误则回滚
#     db.rollback()
#     print("发生错误")


# SQL 删除语句
# sql = "DELETE FROM MESSAGE WHERE view = %s" % (0)
# try:
#    # 执行SQL语句
#    cursor.execute(sql)
#    # 提交修改
#    print("删除成功")
#    db.commit()
# except:
#    # 发生错误时回滚
#    print("发生错误")
#    db.rollback()


# SQL 更新语句
# sql = "UPDATE MESSAGE SET text = 'ganma' WHERE person = 'hery'"
# try:
#    # 执行SQL语句
#    cursor.execute(sql)
#    # 提交到数据库执行
#    db.commit()
#    print("更新成功")
# except:
#    # 发生错误时回滚
#    db.rollback()
#    print("更新失败")

# SQL 查询语句
# sql = "SELECT * FROM MESSAGE \
#        WHERE view = %s" % (1)
# try:
#    # 执行SQL语句
#    cursor.execute(sql)
#    # 获取所有记录列表
#    results = cursor.fetchall()
#    for row in results:
#       ID = row[0]
#       text = row[1]
#       person = row[2]
#       view = row[3]
#       time = row[4]
#        # 打印结果
#       print ("ID=%s,text=%s,person=%s,view=%s,time=%s" % \
#              (ID, text, person, view, time))
# except:
#    print ("Error: unable to fetch data")

# 关闭数据库连接
db.close()
